package cn.lgwen.candy.runtime.operator;

/**
 * 2019/12/24
 * aven.wu
 * danxieai258@163.com
 * I input type of data
 */
public abstract class SinkOperator<I> extends AbstractOperator {

    /**
     * write the given value to sink.
     * @param input
     */
    public abstract void invoke(I input);

}
